package com.central.common.entity;

import com.central.common.enums.DbType;
import com.central.common.enums.EngineType;
import com.central.common.model.TableInfo;
import lombok.Getter;
import lombok.Setter;

import java.util.List;
import java.util.Map;

/**
 * @author Tindy
 * @date 2021/12/1
 * @describe
 */
@Getter
@Setter
public class FlinkSqlTaskContent implements TaskContent {
    private String sql;
    private Long queueId;
    private List<Long> udfIds;
    private Map<String,String> setParams;
    private Map<String,FlinkTable> tableMap;
    private FlinkRunOptions runOptions;
}
